package org.uiot.process

import org.apache.flink.api.java.ExecutionEnvironment

trait BatchJobTraits implements FlinkJobTraits {

    ExecutionEnvironment getBatchExecutionEnvironment() {
        ExecutionEnvironment.createRemoteEnvironment(flinkInst.host, flinkInst.port, null)
    }

    abstract void submit(String operator, String params)
}